7d76f3a061ace87e4b6a4b5684fae32f24dd2183,cdap-data-fabric/src/test/java/co/cask/cdap/data2/transaction/queue/QueueTest.java,QueueTest,testClearOrDropAllForFlow,#boolean#,634

Before Change


    QueueConsumer consumer1 = queueClientFactory.createConsumer(queueName1, consumerConfig, 1);
    QueueConsumer consumer2 = queueClientFactory.createConsumer(queueName2, consumerConfig, 1);
    QueueConsumer consumer3 = queueClientFactory.createConsumer(queueName3, consumerConfig, 1);
    txContext = createTxContext(consumer1, consumer2, consumer3);
    txContext.start();
    for (QueueConsumer consumer : Arrays.asList(consumer1, consumer2, consumer3)) {
      DequeueResult<byte[]> result = consumer.dequeue(1);
      Assert.assertFalse(result.isEmpty());
      Assert.assertArrayEquals(Bytes.toBytes(0), result.iterator().next());
    }
    txContext.finish();

    // verify the consumer config was deleted
    verifyConsumerConfigExists(queueName1, queueName2);

After Change


      QueueConsumer consumer2 = queueClientFactory.createConsumer(queueName2, consumerConfig, 1);
      QueueConsumer consumer3 = queueClientFactory.createConsumer(queueName3, consumerConfig, 1)
    ) {
      TransactionContext txContext = createTxContext(consumer1, consumer2, consumer3);
      txContext.start();
      for (QueueConsumer consumer : Arrays.asList(consumer1, consumer2, consumer3)) {
        DequeueResult<byte[]> result = consumer.dequeue(1);
        Assert.assertFalse(result.isEmpty());
        Assert.assertArrayEquals(Bytes.toBytes(0), result.iterator().next());
      }
      txContext.finish();
    }

    // verify the consumer config was deleted